package com.dao.impl;

import com.dao.BaseDao;
import com.dao.MsgDao;
import com.entity.Msg;

import java.util.List;

public class MsgDaoImpl extends BaseDao implements MsgDao {
    @Override
    public List<Msg> findByLoginName(String name) {
        String sql = "SELECT * from msg where sendto = ?";
        Object[] obj = {name};
        return (List<Msg>) query(sql,obj,Msg.class);
    }

    @Override
    public Msg findByMsgId(int msgid) {
        String sql = "select * from msg where msgid = ?";
        Object[] obj = {msgid};
        List<Msg> list = (List<Msg>) query(sql,obj,Msg.class);
        return list!= null && list.size() > 0?list.get(0):null;
    }

    @Override
    public int addMsg(Msg msg) {
        String sql = "insert into msg(username,title,msgcontent,sendto) VALUES(?,?,?,?)";
        Object[] obj = {msg.getUsername(),msg.getTitle(),msg.getMsgcontent(),msg.getSendto()};
        return saveOrUpdateORDel(sql,obj);
    }
}
